package model

import (
	"time"
)

type EventConsumer struct {
	Key      string
	Callback func(*Event)
}

type Event struct {
	Key        string
	Id         int64
	Msg        map[string]interface{}
	CreateTime time.Time
}
